package com.binarysoft.service.common.ping;


public class ReceiveThread extends Thread{
	private PingServiceBean pingService;
	
	public ReceiveThread(PingServiceBean pingService){
		super("Ping_ReceiveThread");
		this.pingService = pingService;
	}
	
	
	
	public void run(){
		while (!this.pingService.isServiceClosed()) {
			this.pingService.receiveEchoReply();
		}
		this.pingService.countDown(); // 通知CPingService,本线程运行已经结束
	}
	
}
